package cn.dapeng.rpc.common.handler;


import cn.dapeng.rpc.common.RpcResponse;
import cn.dapeng.rpc.common.cb.ResponseCallBackV2;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

public class ClientResponseHandler extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        RpcResponse result = (RpcResponse) msg;
        //ResponseCallBackV1.runCallback(result.getRequestId());
        ResponseCallBackV2.runCallback(result);
    }
}
